package com.yellowcong.grpc.impl;

import com.yellowcong.model.GreeterGrpc;
import com.yellowcong.model.HelloReply;
import com.yellowcong.model.HelloRequest;

import io.grpc.stub.StreamObserver;

/**
 * 代码创建: yellowcong <br/>
 * 创建日期: 2019年1月21日 <br/>
 * 功能描述: 
 */
public class GreeterImpl extends GreeterGrpc.GreeterImplBase {

    public void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) {
        //获取参数
        System.out.println("收到的信息:"+req.getName());

        //这里可以放置具体业务处理代码 start

        //这里可以放置具体业务处理代码 end

        //构造返回
        HelloReply reply = HelloReply.newBuilder().setMessage(("Hello: " + req.getName())).build();
        responseObserver.onNext(reply);
        responseObserver.onCompleted();
    }
}
